package com.cyf.mq.constant;

/**
 * @author chenyifan
 * @create 2025-02-18 15:08
 */
public class MqConstant {

    public static final String NAME_SERVER_ADDR = "127.0.0.1:9876";

    public static final String MESSAGE_CONSUMER_GROUP_A = "consumer_group_A";
    public static final String MESSAGE_CONSUMER_GROUP_B = "consumer_group_B";

    public static final String MESSAGE_PRODUCER_GROUP_A = "producer_group_A";


    public static final String MESSAGE_DEAD_CONSUMER_GROUP = "retry-dead-consumer-group";


    /**
     * Topic 主题定义
     */
    public static final String MESSAGE_TOPIC_King = "topic_king";

}
